<?php
namespace WxpayAPI;

use app\api\service\MemberMoney;
use think\Db;
use Des3\DES3;
use app\api\service\Message;
use app\api\service\Common;

//require_once "WxPayApi.php";
/**
 *
 * 回调基础类
 * @author widyhu
 *
 */
class WxPayNotify extends WxPayNotifyReply
{

    /**
     *
     * 回调入口
     * @param bool $needSign 是否需要签名输出
     */
    final public function Handle($needSign = true)
    {
        $msg = "OK";
        //当返回false的时候，表示notify中调用NotifyCallBack回调失败获取签名校验失败，此时直接回复失败
        $result = WxPayApi::notify(array($this, 'NotifyCallBack'), $msg);

        if ($result == false) {
            $this->SetReturn_code("FAIL");
            $this->SetReturn_msg($msg);
            $this->ReplyNotify(false);
            return;
        } else {
            //该分支在成功回调到NotifyCallBack方法，处理完成之后流程
            $this->SetReturn_code("SUCCESS");
            $this->SetReturn_msg("OK");
        }
        $this->ReplyNotify($needSign);
    }

    /**
     *
     * 回调方法入口，子类可重写该方法
     * 注意：
     * 1、微信回调超时时间为2s，建议用户使用异步处理流程，确认成功之后立刻回复微信服务器
     * 2、微信服务器在调用失败或者接到回包为非确认包的时候，会发起重试，需确保你的回调是可以重入
     * @param array $data 回调解释出的参数
     * @param string $msg 如果回调处理失败，可以将错误信息输出到该方法
     * @return true回调出来完成不需要继续回调，false回调处理未完成需要继续回调
     */
    //重写回调处理函数
    public function NotifyProcess($data, &$msg)
    {
        if (!array_key_exists("transaction_id", $data)) {
        $msg = "输入参数不正确";
        return false;
    }


        //查询订单，判断订单真实性
        if (!$this->Queryorder($data["transaction_id"])) {
            $msg = "订单查询失败";
            return false;
        } else {
            $pay_sn = $data["transaction_id"]; //支付单号
            $out_trade_no = $data['out_trade_no']; //订单号
            $order_price = $data['total_fee'] / 100; //订单支付金额

            // 获取商家数据包
            $attach = json_decode($data['attach'], true);
            //验证回调身份
            $des3 = new \Des3\DES3();
            if($des3->decrypt($attach['sign']) != 'jxtx.com') {
                return false;
            }
            $pay_result = \app\api\service\Pay::pay_notify($order_price, $out_trade_no, $pay_sn, 'wechat', '微信支付');
            if ($pay_result) {
                // 支付成功
                return true; // 请不要修改或删除
            } else {
                // 支付失败
                return false; // 请不要修改或删除
            }
        }

        return true;
    }

    /**
     *
     * notify回调方法，该方法中需要赋值需要输出的参数,不可重写
     * @param array $data
     * @return true回调出来完成不需要继续回调，false回调处理未完成需要继续回调
     */
    final public function NotifyCallBack($data)
    {
        $msg = "OK";
        $result = $this->NotifyProcess($data, $msg);

        if ($result == true) {
            $this->SetReturn_code("SUCCESS");
            $this->SetReturn_msg("OK");
        } else {
            $this->SetReturn_code("FAIL");
            $this->SetReturn_msg($msg);
        }
        return $result;
    }

    /**
     *
     * 回复通知
     * @param bool $needSign 是否需要签名输出
     */
    final private function ReplyNotify($needSign = true)
    {
        //如果需要签名
        if ($needSign == true && $this->GetReturn_code() == "SUCCESS") {
            $this->SetSign();
        }
        $xml = $this->ToXml();
//        file_put_contents("test.txt", $xml, FILE_APPEND);
        WxPayApi::replyNotify($xml);
    }

    //查询订单
    public function Queryorder($transaction_id)
    {
        $input = new WxPayOrderQuery();
        $input->SetTransaction_id($transaction_id);
        $result = WxPayApi::orderQuery($input);
        //\Think\Log::record("query:" . json_encode($result));
        if (array_key_exists("return_code", $result) && array_key_exists("result_code", $result) && $result["return_code"] == "SUCCESS" && $result["result_code"] == "SUCCESS") {
            return true;
        }
        return false;
    }

}
